632947856f9195b9e74984facd584f0a41646c7c,spark/src/test/java/org/apache/zeppelin/spark/SparkSqlInterpreterTest.java,SparkSqlInterpreterTest,setUp,#,49

Before Change


    p.setProperty("zeppelin.spark.concurrentSQL", "false");
    p.setProperty("zeppelin.spark.sql.stacktrace", "false");

    if (repl == null) {

      if (SparkInterpreterTest.repl == null) {
        repl = new SparkInterpreter(p);
        intpGroup = new InterpreterGroup();
        repl.setInterpreterGroup(intpGroup);
        repl.open();
        SparkInterpreterTest.repl = repl;
        SparkInterpreterTest.intpGroup = intpGroup;
      } else {
        repl = SparkInterpreterTest.repl;
        intpGroup = SparkInterpreterTest.intpGroup;
      }

      sql = new SparkSqlInterpreter(p);

      intpGroup = new InterpreterGroup();
      intpGroup.put("note", new LinkedList<Interpreter>());
      intpGroup.get("note").add(repl);
      intpGroup.get("note").add(sql);
      sql.setInterpreterGroup(intpGroup);
      sql.open();
    }
    context = new InterpreterContext("note", "id", null, "title", "text", new AuthenticationInfo(),

After Change


    repl = new SparkInterpreter(p);
    intpGroup = new InterpreterGroup();
    repl.setInterpreterGroup(intpGroup);
    repl.open();
    SparkInterpreterTest.repl = repl;
    SparkInterpreterTest.intpGroup = intpGroup;

    sql = new SparkSqlInterpreter(p);

    intpGroup = new InterpreterGroup();
    intpGroup.put("note", new LinkedList<Interpreter>());
    intpGroup.get("note").add(repl);
    intpGroup.get("note").add(sql);
    sql.setInterpreterGroup(intpGroup);
    sql.open();

    context = new InterpreterContext("note", "id", null, "title", "text", new AuthenticationInfo(),